package com.gitee.xhs;

import com.gitee.xhs.sampleRecod.transactionRecord.Transaction;
import org.apache.flink.api.common.state.MapStateDescriptor;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.util.OutputTag;

/**
 * @author BigHead
 * @date 2022/7/19 16:40
 * @description OperatorConstant
 */
public class OperatorConstant {

    public static final MapStateDescriptor<Integer, Transaction> SEPARATION_TRANSACTION_MAP_STATE = new MapStateDescriptor<>(
            "SEPARATION_TRANSACTION_MAP_STATE",
            TypeInformation.of(Integer.class),
            TypeInformation.of(Transaction.class)
    );


    public static final OutputTag<Transaction> ITERATOR_OUT_PUT_TAG = new OutputTag<Transaction>("ITERATOR_OUT_PUT_TAG") {
    };
    public static final OutputTag<Transaction> INTERVAL_JOIN_OUT_PUT_TAG = new OutputTag<Transaction>("INTERVAL_JOIN_OUT_PUT_TAG") {
    };
    public static final OutputTag<Transaction> LATENESS_OUT_PUT_TAG = new OutputTag<Transaction>("LATENESS_OUT_PUT_TAG") {
    };
}
